package paas.storage.distributedColumnDatabase;

import paas.storage.result.ExportDataResponse;
import paas.storage.result.ImportDataResponse;

import java.io.IOException;

/**
 * 数据管理
 *
 * @author xufeng
 * @email 525207937@qq.com
 * @date 2021/1/26 16:37
 */
public interface IManagement {
    /**
     * 数据导入
     *
     * @param connectionId   连接 必填
     * @param database       数据库 不必填
     * @param table          表 必填
     * @param sourceFileType 文件类型 必填
     * @param sourceFilePath 文件路劲 必填
     * @return
     */
    ImportDataResponse importData(String connectionId, String database, String table, String sourceFileType, String sourceFilePath);

    /**
     * 导出
     *
     * @param connectionId 连接 必填
     * @param database 数据库 不必填
     * @param table 表 必填
     * @param destFileType 文件类型 必填
     * @param destFilePath 文件路劲 必填
     * @return
     */
     ExportDataResponse exportData(String connectionId, String database, String table, String destFileType, String destFilePath);
}
